package org.rency.mq.activemq.listener.handler;

import org.rency.mq.activemq.request.MQRequest;

/**
 * 消息处理器
 * 
 * 消息监听器收到消息后，最终交给消息处理器进行处理
 *
 */
public interface MessageHandler<T> {
	/**
	 * 处理消息内容
	 * @param request
     */
	public void handle(T request);

	/**
	 * 处理消息内容
	 * @param request
	 * @throws Exception
     */
	public void handleMessage(T request) throws Exception;
	
	/**
	 * 将消息内容转换为MQRequest
	 * @param request	消息内容
	 * @return
	 */
	public MQRequest convertToMQRequest(T request);
}
